from ActiveMqDemo.Core.ActiveMQ import ActiveMQ
from ActiveMqDemo.GradientBoostingRegressorDemo.Task import MachineTaskListener

host = "127.0.0.1"
port = 61613

listener = MachineTaskListener(host, port)  # 构建监听类，所有真正的需要Python处理的东西都放在这个类中
activeMq = ActiveMQ(host, port, listener)  # 构建消息中间件
activeMq.init_server("/queue/Task")  # 这个要和CSharp队列同样名称，用来双边通信
